package com.hank.activemq.plugins;

import org.apache.activemq.broker.Broker;
import org.apache.activemq.broker.BrokerPlugin;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class ClientConnAclPlugin implements BrokerPlugin {

    private static final Logger log= LoggerFactory.getLogger(ClientConnAcl.class);

    @Override
    public Broker installPlugin(Broker broker) throws Exception {
        log.info("初始化自定义插件... ...");
        return new ClientConnAcl(broker);
    }
}
